package com.geek.zeus.demos.web.mq.config;

import com.geek.zeus.demos.web.mq.MQConstants;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.amqp.core.Queue;

/**
 * Created with IntelliJ IDEA.
 *
 * @Author: geek
 * @Date: 2025/10/11/17:09
 * @Description: 直连模式只需要声明队列，所有消息都通过队列转发。
 */
@Configuration
public class DirectConfig {
    @Bean
    public Queue directQueue() {
        return new Queue(MQConstants.QUEUE_DIRECT);
    }
}
